/**
 * @author: yasen
 * @time: 2022/10/11 10:52
 * @email: yasen@yasenstudio.com
 */
package com.showdor.springboot;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.support.Acknowledgment;

import java.util.List;

public interface ConsumerRecordDAO {
    public <K> void create(K key, List<ConsumerRecord<String, String>> records, Acknowledgment ack);

    public <K, V> void create(K key, V value, Acknowledgment ack);
}
